package com.hdu.dwh.service.topic_service;

import org.apache.paimon.flink.action.cdc.schema.JdbcSchemasInfo.JdbcSchemaInfo;

/**
 * 主题数据
 */
public abstract class TopicData {
    protected JdbcSchemaInfo schemaInfo;

    public abstract String buildCreateSQL();

    public abstract boolean checkTableSchema(JdbcSchemaInfo schemaInfo);
}
